# 假设sales_data_df是已经加载好的DataFrame，包含OrderID, Product, Quantity, Price等列  
  
# 如果需要，可以使用.filter()方法筛选DataFrame  
# 例如：筛选出某个时间段内的订单  
# filtered_df = sales_data_df.filter(...)  
  
# 使用.groupBy()方法按产品名称分组  
grouped_df = sales_data_df.groupBy("Product")  
  
# 在分组后的DataFrame上应用.agg()方法进行聚合统计  
# 计算总销售数量（Quantity的总和）和总销售额（Quantity * Price的总和）  
aggregated_df = grouped_df.agg(  
    {"Quantity": "sum"}.alias("TotalQuantity"),  # 总销售数量  
    (sales_data_df["Quantity"] * sales_data_df["Price"]).alias("TotalSales")  # 总销售额  
)  
aggregated_df.show()